package org.springblade.handle;

import org.springblade.common.constant.ProtocolConstant;
import org.springblade.codec.TcpCodec;

import java.util.HashMap;
import java.util.Map;

/**
 * 消息编解码分配
 * @author 李家民
 */
public class MsgDispatcher {

	private static Map<Integer, CodecAdapter> msgCodecMap = new HashMap<>();

	static {
		// 字典表协议匹配
		msgCodecMap.put(ProtocolConstant.TCP_SERVER, new TcpCodec());
		msgCodecMap.put(ProtocolConstant.TCP_CLIENT, new TcpCodec());
	}

	public static CodecAdapter getCodecAdapter(Integer protocol) {
		return msgCodecMap.get(protocol);
	}

}
